import redis
import json
import pymongo

client = redis.Redis()  # 初始化redis
handler = pymongo.MongoClient().chatper_8.people_info  # 初始化mongo

people_info_list = []
while True:  # 开启一个永远运行的循环。
    people_info_json = client.lpop('people_info')  # 在Redis中名为people_info的列表左侧获取一条数据,并将数据赋值给people_info_json变量。
    if people_info_json:
        # 如果people_info_json不为空,则使用JSON模块把它转换为字典,然后将其添加到people_info_list列表中。

        people_info = json.loads(people_info_json.decode())
        people_info_list.append(people_info)
    else:  # 如果people_info_json为空,则说明Redis数据己经读完,跳出循环。
        break
handler.insert_many(people_info_list)  # 把people_info_list中的数据批量插入MongoDB。
